package com.sfd.jdbcutils;

import java.sql.Connection;

import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
/**
 * 1.在运行之前 先启动 hiveserver （hive --service hiveserver）
 * 2.导入依赖jar包时 需要在hive和hadoop中同时查找
 * 3.url的赋值时，指不指定hive中的数据库都一样，默认进入的是default数据库
 * @author qiqi
 *
 */
public class JDBCUtils {
	
		
	private static String drive="org.apache.hadoop.hive.jdbc.HiveDriver";
		private static String url="jdbc:hive://192.168.3.18:10000";
		
	static {
		try {
			Class.forName(drive);
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
		}
	}
	
	public static  Connection getConnection(){
		Connection conn=null;
		try {
			System.out.println("sgfdsger");
			conn = DriverManager.getConnection(url);
			System.out.println(conn);
		} catch (SQLException e) {
			e.printStackTrace();
		}
		return conn;
	}
	
	public static void release(Connection conn,Statement st,ResultSet rs){
		
		if (rs!=null){
			try {
				rs.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}finally{
				rs=null;
			}
		}
		if(st!=null){
			try {
				st.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}finally{
				st=null;
			}
		}
		if(conn!=null){
			try {
				conn.close();
			} catch (SQLException e) {
				e.printStackTrace();
			}finally{
				conn=null;
			}
		}
		
	}
	
}
